package org.deep.cmd;

import java.util.concurrent.LinkedBlockingQueue;

public abstract class CmdSource {
    public final LinkedBlockingQueue<byte[]> queue = new LinkedBlockingQueue<>();
    public final LinkedBlockingQueue<byte[]> queueFromEvent = new LinkedBlockingQueue<>();

    public abstract void write(byte[] buf);
}
